package com.me.study.rabbitmq.config;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.messaging.SubscribableChannel;

/**
 * @author light
 * @version 1.0
 * @description: 全局接收
 * @date 2021/9/17 10:04
 */
public interface GlobalEventInput {
    String TestDirectExchange_INPUT ="TestDirectExchange_INPUT";
    String TopicExchange_ALL_INPUT ="TopicExchange_ALL_INPUT";
    String TopicExchange_MAN_INPUT ="TopicExchange_MAN_INPUT";
    String FanoutExchange_INPUT ="FanoutExchange_INPUT";
    String DIRECT_EXCHANGE_INPUT ="DIRECT_EXCHANGE_INPUT";
    String DIRECT_BACKUP_EXCHANGE_INPUT ="DIRECT_BACKUP_EXCHANGE_INPUT";
    String LAZY_EXCHANGE_INPUT ="LAZY_EXCHANGE_INPUT";




    @Input(TestDirectExchange_INPUT)
    SubscribableChannel testDirectexchangeInput();

    @Input(TopicExchange_ALL_INPUT)
    SubscribableChannel topicexchangeAllInput();

    @Input(TopicExchange_MAN_INPUT)
    SubscribableChannel topicexchangeManInput();

    @Input(FanoutExchange_INPUT)
    SubscribableChannel fanoutExchangeInput();

    @Input(DIRECT_EXCHANGE_INPUT)
    SubscribableChannel directExchangeInput();

    @Input(DIRECT_BACKUP_EXCHANGE_INPUT)
    SubscribableChannel directbackupExchangeInput();

    @Input(LAZY_EXCHANGE_INPUT)
    SubscribableChannel lazyExchangeInput();

}
